package spendreport.service;

import org.apache.flink.streaming.api.functions.sink.SinkFunction;
import org.apache.flink.walkthrough.common.sink.AlertSink;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import spendreport.pojo.AccountTransation;

public class AccountAlertSink implements SinkFunction<AccountTransation> {

	/**
	 * 
	 */
	private static final long serialVersionUID = 1L;
	private static final Logger LOG = LoggerFactory.getLogger(AlertSink.class);

	@Override
	public void invoke(AccountTransation value, Context context) {
		LOG.info(value.toString());
	}
}
